package com.apex.spark.utils;

/**
 * 配置文件管理
 */
public class ConfigKeyName {

    // env
    public final static String SPARK_CONF = "job.setting.env.spark.conf";
    public final static String SPARK_RUNTIME_MODE = "job.setting.env.spark.mode";
    public final static String SPARK_JOB_NAME = "job.setting.name";
    public final static String SPARK_MASTER_KEY_NAME = "master";
    public final static String JOB_ENGINE = "job.setting.engine";
    public final static String SPARK_BATCH_DURATION = "job.setting.env.spark.stream.batchDuration";
    public final static String SPARK_RUN_HIVE_MODE = "job.setting.enableHive";
    //
    public final static String JOB_SOURCE_PLUGIN_NAME = "job.source.plugin.name";
    public final static String JOB_TRANSFORM_PLUGIN_NAME = "job.transform.plugin.name";
    public final static String JOB_SINK_PLUGIN_NAME = "job.sink.plugin.name";

    //plugin reader
    public final static String READ_FILE_PATH = "job.source.plugin.file.path";
    public final static String FILE_SPLIT = "job.source.plugin.file.split";
    public final static String READ_FILE_TYPE = "job.source.plugin.file.type";

    //transform

    public final static String SPARK_RUN_SQL = "job.transform.sql.result";
    public final static String SPARK_RUN_SQLFile = "job.transform.sql.scriptFile";
    public final static String SPARK_RUN_WORKSPACE = "job.transform.sql.workSpace";
    public final static String SPARK_TABLE_SCHEMA = "job.transform.schema";
    public final static String GROK_PATTERN_PATH = "job.transform.plugin.grok.path";
    public final static String GROK_PATTERN = "job.transform.plugin.grok.pattern";

    //writer
    public final static String SPARK_WRITER_PATH = "job.sink.plugin.file.path";
    public final static String SPARK_WRITER_FILE_TYPE = "job.sink.plugin.file.type";
    public final static String SPARK_WRITER_FILE_PARALLELISM = "job.sink.plugin.file.parallelism";
    public final static String SPARK_WRITER_FILE_SEPARATOR = "job.sink.plugin.file.textSeparator";

    //jdbc properties
    public final static String DRIVER_CLASS_READER = "job.source.plugin.env.driver";
    public final static String JDBC_URL_READER = "job.source.plugin.env.url";
    public final static String JDBC_USER_NAME_READER = "job.source.plugin.env.user";
    public final static String JDBC_PASSWORD_READER = "job.source.plugin.env.password";
    public final static String JDBC_TABLE_READER = "job.source.plugin.env.table";
    public final static String JDBC_OPTIONS_READER = "job.source.plugin.env.jdbcOptions";
    public final static String JDBC_OPTIONS_QUERY = "job.source.plugin.env.query";
    // writer
    public final static String DRIVER_CLASS_WRITER = "job.sink.plugin.env.driver";
    public final static String JDBC_URL_WRITER = "job.sink.plugin.env.url";
    public final static String JDBC_USER_NAME_WRITER = "job.sink.plugin.env.user";
    public final static String JDBC_PASSWORD_WRITER = "job.sink.plugin.env.password";
    public final static String JDBC_TABLE_WRITER = "job.sink.plugin.env.table";
    public final static String JDBC_OPTIONS_WRITER = "job.sink.plugin.env.jdbcOptions";
    //elasticsearch
    public final static String ELASTIC_WRITER_NODES = "job.sink.plugin.env.esNodes";
    public final static String ELASTIC_WRITER_PORT = "job.sink.plugin.env.esPort";
    public final static String ELASTIC_WRITER_USER = "job.sink.plugin.env.esUser";
    public final static String ELASTIC_WRITER_PASSWORD = "job.sink.plugin.env.esPassword";
    public final static String ELASTIC_WRITER_INDEX = "job.sink.plugin.env.esIndex";
    //reader
    public final static String ELASTIC_READER_NODES = "job.source.plugin.env.esNodes";
    public final static String ELASTIC_READER_PORT = "job.source.plugin.env.esPort";
    public final static String ELASTIC_READER_USER = "job.source.plugin.env.user";
    public final static String ELASTIC_READER_PASSWORD = "job.source.plugin.env.password";
    public final static String ELASTIC_READER_INDEX = "job.source.plugin.env.esIndex";
    //hbase
    public final static String HBASE_ZOOKEEPER_QUORUM = "job.hbase.env.zookeeper";
    public final static String HBASE_MASTERP_RINCIPAL = "job.hbase.env.masterPrincipal";
    public final static String HBASE_REGIONSERVER_PRINCIPAL = "job.hbase.env.regionserverPrincipal";
    public final static String HBASE_ZNODEPARENT = "job.hbase.env.znodeParent";
    public final static String HBASE_CONF_PATH = "job.hbase.env.hadoopConfDir";
    public final static String HBASE_ROWKEY = "job.hbase.env.rowkey";
    public final static String HBASE_FAMILY = "job.hbase.env.family";
    public final static String HBASE_TABLE_NAME = "job.hbase.env.tableName";
    public final static String HBASE_KEYTAB = "job.hbase.env.keytab";
    public final static String HBASE_USER_PRINCIPAL = "job.hbase.env.principal";
    public final static String HBASE_JAAS_FILE = "job.hbase.env.jaas";
    public final static String HBASE_KRB_PATH = "job.hbase.env.krb";
    public final static String HBASE_IS_KERBEROS = "job.hbase.env.isKerberos";
    public final static String HBASE_GET_DATA = "job.hbase.env.get.row";
    public final static String HBASE_SCAN_CACHE_SIZE = "job.hbase.env.scan.cacheSize";
    public final static String HBASE_SCAN_START_ROW = "job.hbase.env.scan.startRow";
    public final static String HBASE_SCAN_STOP_ROW = "job.hbase.env.scan.stopRow";
    public final static String HBASE_GET_DATA_METHOD = "job.hbase.env.scan.method";
}
